32.1.6 接收消息

当JMS基础设施能够使用时,任何bean都能够被@JmsListener注解,以创建一个监听者端点。如果没有定义JmsListenerContainerFactory,将自动配置一个默认的。如果定义DestinationResolverMessageConverter beans,它们将自动关联该默认factory。

默认factory是事务性的,如果运行的设施出现JtaTransactionManager,它默认将关联到监听器容器。如果没有,sessionTransacted标记将启用。在后一场景中,你可以通过在监听器方法上添加@Transactional,以本地数据存储事务处理接收的消息,这可以确保接收的消息在本地事务完成后只确认一次。

下面的组件创建了一个以someQueue为目标的监听器端点:

@Component
public class MyBean {
@JmsListener(destination = "someQueue")
public void processMessage(String content) {
// ...
}
}

具体查看@EnableJms javadoc

如果想创建多个JmsListenerContainerFactory实例或覆盖默认实例,你可以使用Spring Boot提供的DefaultJmsListenerContainerFactoryConfigurer,通过它可以使用跟自动配置的实例相同配置来初始化一个DefaultJmsListenerContainerFactory

例如,以下使用一个特殊的MessageConverter创建另一个factory:

@Configuration
static class JmsConfiguration {

    @Bean
    public DefaultJmsListenerContainerFactory myFactory(
            DefaultJmsListenerContainerFactoryConfigurer configurer) {
        DefaultJmsListenerContainerFactory factory =
                new DefaultJmsListenerContainerFactory();
        configurer.configure(factory, connectionFactory());
        factory.setMessageConverter(myMessageConverter());
        return factory;
    }

}

然后,你可以像下面那样在任何@JmsListener注解中使用:

@Component
public class MyBean {

    @JmsListener(destination = "someQueue", containerFactory="myFactory")
    public void processMessage(String content) {
        // ...
    }

}